［アップデート］AWS IoT Coreでモノの属性をメッセージに伝播させる機能が追加されました！

from awsiot import mqtt5_client_builder
from awscrt import mqtt5
from concurrent.futures import Future
import time
import json

TIMEOUT = 100
client_id = "vehicle-001"
message_topic = "vehicle/test"
endpoint = "xxxxxxxxxxxxx-ats.iot.ap-northeast-1.amazonaws.com"
cert_path = f"certs/{client_id}-certificate.pem.crt"
private_key_path = f"certs/{client_id}-private.pem.key"
root_ca_path = "./AmazonRootCA1.pem"

message_count = 1
data = {"message": "Hello, MQTT!"}

future_stopped = Future()
future_connection_success = Future()

# Callback for the lifecycle event Stopped
def on_lifecycle_stopped(lifecycle_stopped_data: mqtt5.LifecycleStoppedData):
    print("Lifecycle Stopped")
    global future_stopped
    future_stopped.set_result(lifecycle_stopped_data)

# Callback for the lifecycle event Connection Success
def on_lifecycle_connection_success(
    lifecycle_connect_success_data: mqtt5.LifecycleConnectSuccessData,
):
    print("Lifecycle Connection Success")
    global future_connection_success
    future_connection_success.set_result(lifecycle_connect_success_data)

# Callback for the lifecycle event Connection Failure
def on_lifecycle_connection_failure(
    lifecycle_connection_failure: mqtt5.LifecycleConnectFailureData,
):
    print("Lifecycle Connection Failure")
    print(
        "Connection failed with exception:{}".format(
            lifecycle_connection_failure.exception
        )
    )

if __name__ == "__main__":
    print("\nStarting MQTT5 Publish Sample\n")

    # プロキシオプションの作成
    proxy_options = None
    # プロキシ設定が必要な場合は適宜設定

    # MQTT5クライアントの作成
    client = mqtt5_client_builder.mtls_from_path(
        endpoint=endpoint,
        port=8883,  # 必要に応じて変更
        cert_filepath=cert_path,
        pri_key_filepath=private_key_path,
        ca_filepath=root_ca_path,
        http_proxy_options=proxy_options,
        on_lifecycle_stopped=on_lifecycle_stopped,
        on_lifecycle_connection_success=on_lifecycle_connection_success,
        on_lifecycle_connection_failure=on_lifecycle_connection_failure,
        client_id=client_id,
    )
    print("MQTT5 Client Created")

    print(f"Connecting to {endpoint} with client ID '{client_id}'...")

    client.start()
    lifecycle_connect_success_data = future_connection_success.result(TIMEOUT)
    connack_packet = lifecycle_connect_success_data.connack_packet
    print(f"Connected to endpoint: '{endpoint}' with Client ID: '{client_id}'")

    if data:
        print("Sending {} message(s)".format(message_count))
        for publish_count in range(1, message_count + 1):
            message = "{} [{}]".format(json.dumps(data), publish_count)
            print("Publishing message to topic '{}': {}".format(message_topic, message))
            publish_future = client.publish(
                mqtt5.PublishPacket(
                    topic=message_topic,
                    payload=json.dumps(data),
                    qos=mqtt5.QoS.AT_LEAST_ONCE,
                )
            )
            publish_completion_data = publish_future.result(TIMEOUT)
            print(
                "PubAck received with {}".format(
                    repr(publish_completion_data.puback.reason_code)
                )
            )
            time.sleep(1)

    print("Stopping Client")
    client.stop()
    future_stopped.result(TIMEOUT)
    print("Client Stopped!")

python mqtt_client.py

Starting MQTT5 Publish Sample

MQTT5 Client Created
Connecting to xxxxxxxxxxxxx-ats.iot.ap-northeast-1.amazonaws.com with client ID 'vehicle-001'...
Lifecycle Connection Success
Connected to endpoint: 'xxxxxxxxxxxxx-ats.iot.ap-northeast-1.amazonaws.com' with Client ID: 'vehicle-001'
Sending 1 message(s)
Publishing message to topic 'vehicle/test': {"message": "Hello, MQTT!"} [1]
PubAck received with <PubackReasonCode.SUCCESS: 0>
Stopping Client
Lifecycle Stopped
Client Stopped!